feat(parser): implemented a helper function Base64Encoded to decode base64 encoded payloads
#4413
Conversation
boring-cyborg
bot
added
parser
There was a problem hiding this comment.
Should we use the new helper in the Kinsis schema here (packages/parser/src/schemas/kinesis.ts) similar to how we use the DynamoDB one in the DynamoDB schema here?
|
@dreamorosi The dynamodb helper doesn't seem to be used in that schema, it's only referenced in the comments. It's using |
|
If I understand the new helper correctly, you should be able to replace these lines here with something like this: const KinesisDataStreamRecordPayload = z.object({
kinesisSchemaVersion: z.string(),
partitionKey: z.string(),
sequenceNumber: z.string(),
approximateArrivalTimestamp: z.number(),
data: Base64Encoded(z.any()), // or z.unknown()
});and also remove the |
|
2 participants
Summary
This PR adds a helper function which decodes a base64 encoded payload and parses the decoded payload with the schema passed to the function
Changes
Issue number: closes #4412
By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.
Disclaimer: We value your time and bandwidth. As such, any pull requests created on non-triaged issues might not be successful.